home *** CD-ROM | disk | FTP | other *** search
- import java.io.DataInputStream;
- import java.io.DataOutputStream;
- import java.io.IOException;
- import java.net.Socket;
- import java.util.Vector;
-
- class MuDispatcher extends Thread {
- // $FF: renamed from: in java.io.DataInputStream
- DataInputStream field_0;
- DataOutputStream out;
- Vector clients;
-
- MuDispatcher(Socket var1, Vector var2, int var3) {
- super("MuDispatcher");
- this.clients = var2;
-
- try {
- this.field_0 = new DataInputStream(var1.getInputStream());
- this.out = new DataOutputStream(var1.getOutputStream());
- this.out.writeInt(var3);
- ((Thread)this).start();
- } catch (IOException var5) {
- ((Throwable)var5).printStackTrace();
- }
- }
-
- public void run() {
- float var3 = 0.0F;
- float var4 = 0.0F;
- float var5 = 0.0F;
- float var6 = 0.0F;
-
- try {
- while(true) {
- int var1 = this.field_0.readInt();
- int var2 = this.field_0.readInt();
- var3 = this.field_0.readFloat();
- var4 = this.field_0.readFloat();
- var5 = this.field_0.readFloat();
- if (var2 == 2) {
- var6 = this.field_0.readFloat();
- }
-
- for(int var7 = 0; var7 < this.clients.size(); ++var7) {
- if (var7 != var1) {
- if (var2 == 2) {
- ((MuDispatcher)this.clients.elementAt(var7)).output(var1, var2, var3, var4, var5, var6);
- } else {
- ((MuDispatcher)this.clients.elementAt(var7)).output(var1, var2, var3, var4, var5);
- }
- }
- }
- }
- } catch (IOException var8) {
- ((Throwable)var8).printStackTrace();
- }
- }
-
- public synchronized void output(int var1, int var2, float var3, float var4, float var5) {
- try {
- this.out.writeInt(var1);
- this.out.writeInt(var2);
- this.out.writeFloat(var3);
- this.out.writeFloat(var4);
- this.out.writeFloat(var5);
- } catch (IOException var7) {
- ((Throwable)var7).printStackTrace();
- }
- }
-
- public synchronized void output(int var1, int var2, float var3, float var4, float var5, float var6) {
- try {
- this.out.writeInt(var1);
- this.out.writeInt(var2);
- this.out.writeFloat(var3);
- this.out.writeFloat(var4);
- this.out.writeFloat(var5);
- this.out.writeFloat(var6);
- } catch (IOException var8) {
- ((Throwable)var8).printStackTrace();
- }
- }
- }
-